org.springframework.http.server.reactive

Class ChannelSendOperator.WriteCompletionBarrier

java.lang.Object

org.springframework.http.server.reactive.ChannelSendOperator.WriteCompletionBarrier

Enclosing class:

ChannelSendOperator<T>

private class ChannelSendOperator.WriteCompletionBarrier
extends java.lang.Object

We need an extra barrier between the WriteBarrier itself and the actual completion subscriber.

The completionSubscriber is subscribed initially to the WriteBarrier. Later after the first signal is received, we need one more subscriber instance (per spec can only subscribe once) to subscribe to the write function and switch to delegating completion signals from it.

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	completionSubscriber
private ChannelSendOperator.WriteBarrier	writeBarrier

Constructor Summary

Constructors

Constructor and Description
WriteCompletionBarrier(<any> subscriber, ChannelSendOperator.WriteBarrier writeBarrier)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	connect() Connect the underlying completion subscriber to this barrier in order to track cancel signals and pass them on to the write barrier.
Context	currentContext()
void	onComplete()
void	onError(java.lang.Throwable ex)
void	onNext(java.lang.Void aVoid)
void	onSubscribe(Subscription subscription)
void	request(long n)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

completionSubscriber

private final <any> completionSubscriber

writeBarrier

private final ChannelSendOperator.WriteBarrier writeBarrier

Constructor Detail

WriteCompletionBarrier

public WriteCompletionBarrier(<any> subscriber,
                              ChannelSendOperator.WriteBarrier writeBarrier)

Method Detail

connect

public void connect()

Connect the underlying completion subscriber to this barrier in order to track cancel signals and pass them on to the write barrier.

onSubscribe

public void onSubscribe(Subscription subscription)

onNext

public void onNext(java.lang.Void aVoid)

onError

public void onError(java.lang.Throwable ex)

onComplete

public void onComplete()

currentContext

public Context currentContext()

request

public void request(long n)

cancel

public void cancel()